// package com.tiga.streamconsumergroup.consumergroup;
//
// import org.slf4j.Logger;
// import org.slf4j.LoggerFactory;
// import org.springframework.boot.autoconfigure.security.SecurityProperties;
// import org.springframework.cloud.stream.annotation.EnableBinding;
// import org.springframework.cloud.stream.annotation.StreamListener;
// import org.springframework.cloud.stream.messaging.Sink;
//
// /**
//  * consumer group
//  */
// @EnableBinding(value = {Sink.class})
// public class SinkReceiver {
//
//     private static Logger logger = LoggerFactory.getLogger(SinkReceiver.class);
//
//     @StreamListener(Sink.INPUT)
//     public void receive(SecurityProperties.User user) {
//         logger.info("Received: " + user.getName());
//     }
// }